package com.TT.service.mq.kafka;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Service;

/**
 * Created by 苏文广 on 2018/11/23
 */
//@Service(value = "kafkaService")
//public class KafkaProducerService {
//    @Autowired
//    private KafkaTemplate<Integer,String> kafkaTemplate;
//    public void testKafka(){
//        System.err.println("++++++++++++++");
////        kafkaTemplate.sendDefault("苏文广第一次springmvc客户端测试");
//        kafkaTemplate.send("suveng","苏文广第一次springmvc客户端测试");
//    }
//}
